from kafka import KafkaProducer,KafkaConsumer
from kafka import KafkaClient

producer = KafkaProducer()

consumer = KafkaConsumer(*['2206'])

kafka_cli = KafkaClient()